package com.hujifang.elasticsearch.model;

import java.io.Serializable;
import java.util.List;

/**
 * EsJDBC数据源配置
 * Created by Hurricane.Hu on 2016/5/4.
 */
public class EsJDBCConfig implements Serializable{
	private static final long serialVersionUID = 5963474658861808765L;
	private String strategy = "standard";
	private String url;
	private String user;
	private String password;
	private List<EsSqlConfig> sql;
	private String locale;
	private String timezone;
	private String rounding;
	private Integer scale= 2;
	private Boolean autocommit;
	private Integer fetchsize;
	private Integer max_rows;
	private Integer max_retries;
	private String max_retries_wait;
	private String resultset_type;
	private String resultset_concurreny;
	private Boolean ignore_null_values;
	private String column_name_map;
	private Integer query_timeout;
	private String schedule;
	private Long interval;
	private Integer threadpoolsize;
	private String index;
	private String type;
	private String index_settings;
	private String type_mapping;
	private Integer max_bulk_actions = 10000;
	private Integer max_concurrent_bulk_requests;
	private String max_bulk_volume;
	private String max_request_wait;
	private String flush_interval ="5s";

	public String getStrategy() {
		return strategy;
	}

	public void setStrategy(String strategy) {
		this.strategy = strategy;
	}

	public String getUrl() {
		return url;
	}

	public void setUrl(String url) {
		this.url = url;
	}

	public String getUser() {
		return user;
	}

	public void setUser(String user) {
		this.user = user;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}

	public List<EsSqlConfig> getSql() {
		return sql;
	}

	public void setSql(List<EsSqlConfig> sql) {
		this.sql = sql;
	}

	public String getLocale() {
		return locale;
	}

	public void setLocale(String locale) {
		this.locale = locale;
	}

	public String getTimezone() {
		return timezone;
	}

	public void setTimezone(String timezone) {
		this.timezone = timezone;
	}

	public String getRounding() {
		return rounding;
	}

	public void setRounding(String rounding) {
		this.rounding = rounding;
	}

	public Integer getScale() {
		return scale;
	}

	public void setScale(Integer scale) {
		this.scale = scale;
	}

	public Boolean getAutocommit() {
		return autocommit;
	}

	public void setAutocommit(Boolean autocommit) {
		this.autocommit = autocommit;
	}

	public Integer getFetchsize() {
		return fetchsize;
	}

	public void setFetchsize(Integer fetchsize) {
		this.fetchsize = fetchsize;
	}

	public Integer getMax_rows() {
		return max_rows;
	}

	public void setMax_rows(Integer max_rows) {
		this.max_rows = max_rows;
	}

	public Integer getMax_retries() {
		return max_retries;
	}

	public void setMax_retries(Integer max_retries) {
		this.max_retries = max_retries;
	}

	public String getMax_retries_wait() {
		return max_retries_wait;
	}

	public void setMax_retries_wait(String max_retries_wait) {
		this.max_retries_wait = max_retries_wait;
	}

	public String getResultset_type() {
		return resultset_type;
	}

	public void setResultset_type(String resultset_type) {
		this.resultset_type = resultset_type;
	}

	public String getResultset_concurreny() {
		return resultset_concurreny;
	}

	public void setResultset_concurreny(String resultset_concurreny) {
		this.resultset_concurreny = resultset_concurreny;
	}

	public Boolean getIgnore_null_values() {
		return ignore_null_values;
	}

	public void setIgnore_null_values(Boolean ignore_null_values) {
		this.ignore_null_values = ignore_null_values;
	}

	public String getColumn_name_map() {
		return column_name_map;
	}

	public void setColumn_name_map(String column_name_map) {
		this.column_name_map = column_name_map;
	}

	public Integer getQuery_timeout() {
		return query_timeout;
	}

	public void setQuery_timeout(Integer query_timeout) {
		this.query_timeout = query_timeout;
	}

	public String getSchedule() {
		return schedule;
	}

	public void setSchedule(String schedule) {
		this.schedule = schedule;
	}

	public Long getInterval() {
		return interval;
	}

	public void setInterval(Long interval) {
		this.interval = interval;
	}

	public Integer getThreadpoolsize() {
		return threadpoolsize;
	}

	public void setThreadpoolsize(Integer threadpoolsize) {
		this.threadpoolsize = threadpoolsize;
	}

	public String getIndex() {
		return index;
	}

	public void setIndex(String index) {
		this.index = index;
	}

	public String getType() {
		return type;
	}

	public void setType(String type) {
		this.type = type;
	}

	public String getIndex_settings() {
		return index_settings;
	}

	public void setIndex_settings(String index_settings) {
		this.index_settings = index_settings;
	}

	public String getType_mapping() {
		return type_mapping;
	}

	public void setType_mapping(String type_mapping) {
		this.type_mapping = type_mapping;
	}

	public Integer getMax_bulk_actions() {
		return max_bulk_actions;
	}

	public void setMax_bulk_actions(Integer max_bulk_actions) {
		this.max_bulk_actions = max_bulk_actions;
	}

	public Integer getMax_concurrent_bulk_requests() {
		return max_concurrent_bulk_requests;
	}

	public void setMax_concurrent_bulk_requests(Integer max_concurrent_bulk_requests) {
		this.max_concurrent_bulk_requests = max_concurrent_bulk_requests;
	}

	public String getMax_bulk_volume() {
		return max_bulk_volume;
	}

	public void setMax_bulk_volume(String max_bulk_volume) {
		this.max_bulk_volume = max_bulk_volume;
	}

	public String getMax_request_wait() {
		return max_request_wait;
	}

	public void setMax_request_wait(String max_request_wait) {
		this.max_request_wait = max_request_wait;
	}

	public String getFlush_interval() {
		return flush_interval;
	}

	public void setFlush_interval(String flush_interval) {
		this.flush_interval = flush_interval;
	}
}
